package org.hbhk.hms.mq.tx.consumer;

public class ConsumerConfig {
	/**
	 * 消息队列的服务器地址 如果没有设置，则使用全局设置
	 *
	 * @return
	 */
	String serverUrl = "";

	/**
	 * 生产者组名 如果没有设置，则使用全局设置
	 *
	 * @return
	 */
	String group = "";

	/**
	 * 队列名
	 *
	 * @return
	 */
	String topic;

	/**
	 * 队列Tag
	 *
	 * @return
	 */
	String tag = "*";

	/**
	 * 消费者线程池最小线程数
	 *
	 * @return
	 */
	int threadMin = 4;

	/**
	 * 消费者线程池最大线程数
	 *
	 * @return
	 */
	int threadMax = 16;

	/**
	 * 是否使用vip通道, 默认：ture
	 * 
	 * @return boolen
	 */
	boolean vipChannelEnabled = true;

	/**
	 * 默认同时消费, 消费 模式
	 * 
	 * @return ConsumeMode
	 */
	ConsumeMode consumeMode = ConsumeMode.CONCURRENTLY;

	/**
	 * 单元名
	 *
	 * @return
	 */
	String unitName = "";

	/**
	 * 实例名
	 *
	 * @return
	 */
	String instanceName = "DEFAULT";

	public String getServerUrl() {
		return serverUrl;
	}

	public void setServerUrl(String serverUrl) {
		this.serverUrl = serverUrl;
	}

	public String getGroup() {
		return group;
	}

	public void setGroup(String group) {
		this.group = group;
	}

	public String getTopic() {
		return topic;
	}

	public void setTopic(String topic) {
		this.topic = topic;
	}

	public String getTag() {
		return tag;
	}

	public void setTag(String tag) {
		this.tag = tag;
	}

	public int getThreadMin() {
		return threadMin;
	}

	public void setThreadMin(int threadMin) {
		this.threadMin = threadMin;
	}

	public int getThreadMax() {
		return threadMax;
	}

	public void setThreadMax(int threadMax) {
		this.threadMax = threadMax;
	}

	public boolean isVipChannelEnabled() {
		return vipChannelEnabled;
	}

	public void setVipChannelEnabled(boolean vipChannelEnabled) {
		this.vipChannelEnabled = vipChannelEnabled;
	}

	public ConsumeMode getConsumeMode() {
		return consumeMode;
	}

	public void setConsumeMode(ConsumeMode consumeMode) {
		this.consumeMode = consumeMode;
	}

	public String getUnitName() {
		return unitName;
	}

	public void setUnitName(String unitName) {
		this.unitName = unitName;
	}

	public String getInstanceName() {
		return instanceName;
	}

	public void setInstanceName(String instanceName) {
		this.instanceName = instanceName;
	}

}
